<?php
error_reporting(0);
define('IN_QY',true);
session_start();
require("include/common.inc.php");
require_once("include/config.php");
require_once("include/httpUtil.php");
define('SCRIPT','ad_list');
set_time_limit(0);
ini_set('memory_limit', '1000M');//自己根据实际调整


//$sql3 = "select userid , shuyu from tbl_user where id>151443814378";
//$query3 = mysql_query($sql3);
//while ($row= mysql_fetch_array($query3)) {
//
//	$funAndOperate = "affMarkSMS/sendSMS";
//	// 生成body
//	$body = createBasicAuthData();
//	// 在基本认证参数的基础上添加短信内容和发送目标号码的参数
//
//	$body['smsContent'] = '【众晒网】足不出户 嗨GO全球!众晒网海GO专区正式上线啦！第一手的进口底价，让你“剁手”停不下来！累计消费还能兑换精美好礼哦！即刻前往直购通道（t.cn/Red7McF）回T退订';
//
//	$body['to'] = ''.$row['userid'].'';
//
//	$result = post($funAndOperate, $body);
//
//
//}
$now = date("Y-m-d");
$now_after_3_days = date("Y-m-d",strtotime("+3 days"));
$res_arr = c_getRows("select tu.userid,ty.lasttime from tbl_yhq as ty INNER JOIN tbl_user tu ON ty.userid = tu.id WHERE ty.state = 1 AND ty.lasttime <=  '$now_after_3_days' AND ty.lasttime > '$now' limit 50000");
$tel_arr = array_column($res_arr,'userid');
if($tel_arr){
    $tel_str = implode(",",array_unique($tel_arr));
//    $tel_str = '17712390766,13013679550';
    send_msg($tel_str);
}


function send_msg($tel,$i=1)
{
    $funAndOperate = "affMarkSMS/sendSMS";
	// 生成body
	$body = createBasicAuthData();
	// 在基本认证参数的基础上添加短信内容和发送目标号码的参数

	$body['smsContent'] = '【众晒网】亲爱的众晒网会员，您有一条重要消息，请仔细阅读！您账户中的多张优惠券即将失效！请务必不要错过这波优惠福利！快速使用通道请戳（t.cn/RrgaLme）回T退订';
//    $body['templateid'] = '506608924';
	$body['to'] = $tel;

	$result = post($funAndOperate, $body);
	$log = $result;
    $result = @json_decode($result,true);
     if($result && $result['respCode'] == '00000')
     {

     }else{

     }
    $file  = 'log.txt';//要写入文件的文件名（可以是任意文件名），如果文件不存在，将会创建一个
    $content = $log;

    if($f  = file_put_contents($file, $content,FILE_APPEND)){// 这个函数支持版本(PHP 5)
        echo "write success";
    }
    echo $content;

    print_r("本次发送的手机号：");
    print_r($tel);
    print_r("--------------end-----------------------");


}

//$i = 1;
//while(true){
//    $i++ ;
//    $re = c_getRow("select * from tbl_user_send_msg ORDER by nid ASC limit 1 ");
//    send_msg($re['userid'],$i);
//    if(!$re || $i>=15000){
//        //如果队列中没有数据，则结束定时器
//        $file  = 'log.txt';//要写入文件的文件名（可以是任意文件名），如果文件不存在，将会创建一个
//        $content = "停止啦，当前是".$i."条";
//        if($f  = file_put_contents($file, $content,FILE_APPEND)){// 这个函数支持版本(PHP 5)
//            echo "写入成功。<br />";
//        }
//        break;
//    }
//    sleep(8); //每隔8秒循环一次
//}


